package com.gt.stream.req.util

import org.apache.kafka.clients.consumer.ConsumerConfig

object MyUtil {

  def createKafkaParam(): Map[String, Object] = {
    val kafkaPara: Map[String, Object] = Map[String, Object](
      ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG -> "localhost:9092",
      ConsumerConfig.GROUP_ID_CONFIG -> "gid_4_test",
      ConsumerConfig.AUTO_OFFSET_RESET_CONFIG -> "latest", // earliest
      "key.deserializer" -> "org.apache.kafka.common.serialization.StringDeserializer",
      "value.deserializer" -> "org.apache.kafka.common.serialization.StringDeserializer"
    )
    kafkaPara
  }


}
